class UDataConsumer:
    def __init__(self, *args, **kwargs):
        pass

    def poll(self):
        return ''


class UDataProducer:
    def __init__(self, *args, **kwargs):
        pass

    def send(self, data):
        return
